package com.learning.rocketmq.demo;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

/**
 * @author ZhangZhaoYing
 * 2020-9-14
 * QueueConsumerLIS.java
 * 收付消息监听器，核心到收付
 */
@Slf4j
@MQConsumeService(topic = TopicEnum.LISTOSFNEW, tags = {"*"})
public class QueueConsumerLIS extends AbstractMQMsgProcessor {

    private MQConsumeResult result = new MQConsumeResult();

    @Override
    protected MQConsumeResult consumeMessage(String tag, List<String> keys, MessageExt messageExt) {
        String msg = new String(messageExt.getBody());

        return result;
    }

}
